package com.example.demo.bean.queue.disruptor;

public class DisruptorMain {
    public static void main(String[] args){
        //单生产者，生产3条数据
        for (int l = 0; l < 3; l++) {
            OutputEvent output = new OutputEvent();
            output.setId(1 + "");
            DisruptorUtil.producer(output);
        }

        try {
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
